package integration.data.task.api.transformation;

import io.github.bigbird0101.datatransfer.record.Record;

import java.util.Map;

public abstract class Transformer {

    private String transformerName;


    public String getTransformerName() {
        return transformerName;
    }

    public void setTransformerName(String transformerName) {
        this.transformerName = transformerName;
    }

    /**
     * @param record 行记录，UDF进行record的处理后，更新相应的record
     * @param paras  transformer函数参数
     */
    abstract public Record evaluate(Record record, Map<String, Object> paras);


}
